package com.ibs.hadoop.hbase.service.run;

import java.util.List;

import com.ibs.hadoop.hbase.bean.QueryBean;
import com.ibs.hadoop.hbase.bean.UseComplaintBaseClass;
import com.ibs.hadoop.hbase.console.UserComplaintFlow;
import com.ibs.hadoop.hbase.service.complaint.UserComplaintDataQuery;

/**
 * 进行异步的附着的查询
* 源文件名：AttachServiceQuery.java
* 文件版本：1.0.0
* 创建作者：Think
* 创建日期：2016年10月31日
* 修改作者：Think
* 修改日期：2016年10月31日
* 文件描述：TODO
* 版权所有：Copyright 2016 zjhz, Inc. All Rights Reserved.
*/
public class ServiceQueryExec implements ExecuteQuery<QueryBean, List<UseComplaintBaseClass>> {

    @Override
    public List<UseComplaintBaseClass> execute(String key, QueryBean arg) throws InterruptedException {
        UserComplaintDataQuery queryInstance = UserComplaintFlow.getInstance(key);

        List<UseComplaintBaseClass> listResult = queryInstance.query(arg);
        return listResult;
    }

}
